package com.conn;

import java.util.concurrent.*;

public class MessageThreadPool {
    private static ExecutorService pool = Executors.newFixedThreadPool(GlobalData.MESSAGE_POOL_SIZE);

    public static void add(Runnable task) {
        pool.execute(task);
    }

    public static void close() {
        pool.shutdown();
    }
}
